package com.example.rabbitmq.test.processors;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

public interface SystemMesageProcessor {
    String INPUT="inputSystemMessage";
    String OUTPUT="outputSystemMessage";

    @Input(SystemMesageProcessor.INPUT)
    SubscribableChannel input();
    @Output(SystemMesageProcessor.OUTPUT)
    MessageChannel out();
}
